package com.coderg.gmall.order.rabbitmq;

import org.springframework.amqp.core.Message;

/**
 * @Description
 * @Author CoderG
 * @Date 2025/6/13 21:34
 **/
// @Component
public class Consumer {
    // 监听死信队列
    // @RabbitListener(queues = RabbitConfig.BUSINESS_QUEUE)
    public void ListenerQueue(Message message){
        try {
            String data = new String(message.getBody());
            //调用超时取消接口
        } catch (Exception e) {
            //判断是否被消费过 重新投递一次

        }
    }

}
